package org.myfram.flink.flinkonjar.common.properties;

import lombok.Data;

@Data
public class KafkaProperties {

    private KafkaSourceConfig source;
    private KafkaSinkConfig sink;

    @Data
    public static class KafkaSourceConfig {
        private String topic;
        private String groupId;
        private String bootstrapServers;
        private String startingOffsets;
    }

    @Data
    public static class KafkaSinkConfig {
        private String topic;
        private String bootstrapServers;
    }
}